package com.xctech.iot.mqtt.sdk.subscribe.message;

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.IMqttMessageListener;
import org.eclipse.paho.client.mqttv3.MqttMessage;


/**
 * 属性设置 监听
 *
 * @author: liangfeihu
 * @since: 2024-06-11 13:36
 */
@Slf4j
//@Component
public class MqttPropertySetMessageListener implements IMqttMessageListener {

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        log.info("[receiveMessage] 属性设置 req topic={} msg={}", topic, new String(message.getPayload(), "UTF-8"));
    }

}
